bfcb69a2a6a4f82bdec21c8811ac72460a0b5611,hazelcast/src/main/java/com/hazelcast/mapreduce/impl/task/JobSupervisor.java,JobSupervisor,cancelAndNotify,#,168

Before Change



        TrackableJobFuture future = jobTracker.unregisterTrackableJob(jobId);
        jobTracker.unregisterMapCombineTask(jobId);
        jobTracker.unregisterReducerTask(jobId);
        mapReduceService.destroyJobSupervisor(this);

        if (future != null) {

After Change


        if (mapCombineTask != null) {
            mapCombineTask.cancel();
        }
        ReducerTask reducerTask = jobTracker.unregisterReducerTask(jobId);
        if (reducerTask != null) {
            reducerTask.cancel();
        }
        mapReduceService.destroyJobSupervisor(this);